cd64f2c390344894eb5b5437c9a19cbb281f5f50,src/spade/storage/kafka/ServerWriter.java,ServerWriter,writeRecord,#GenericContainer#,89
Before Change
long currentTime = System.currentTimeMillis();
if((currentTime - statsLastReportedTime) >= reportStatsAfterEveryMs){
statsLastReportedTime = currentTime;
printStats();
}
/**
After Change
ProducerRecord<String, GenericContainer> record = new ProducerRecord<>(kafkaTopic, genericContainer);
serverWriter.send(record); //asynchronous send
if(reportingEnabled){
recordCount++;
long currentTime = System.currentTimeMillis();
if((currentTime - lastReportedTime) >= reportEveryMs){
printStats();
lastReportedTime = currentTime;
lastReportedRecordCount = recordCount;
}